package srzy.socket

object RBMsgQueue {

  val queue = new java.util.concurrent.ConcurrentLinkedQueue[(Symbol, String)]

  def apply() = queue

}